e002acab5729f85fe225b62aea5492c8928d188b,cdap-app-templates/cdap-etl/cdap-etl-realtime/src/main/java/co/cask/cdap/template/etl/realtime/ETLWorker.java,ETLWorker,initialize,#WorkerContext#,81

Before Change



    initializeSource(context, config.getSource());
    List<Transformation> transforms = initializeTransforms(context,
                                                           config.getTransforms().or(Lists.<ETLStage>newArrayList()));
    initializeSink(context, config.getSink());

    transformExecutor = new TransformExecutor(transforms, transformMetrics);

After Change


    });

    initializeSource(context, config.getSource());
    List<Transformation> transforms = initializeTransforms(context, config.getTransforms());
    initializeSink(context, config.getSink());

    transformExecutor = new TransformExecutor(transforms, transformMetrics);